package com.example.mq.common;

import lombok.Data;

import java.io.Serializable;

/**
 * 这个类表示调用 basicConsume 所需要的参数
 */
@Data
public class BasicConsumeArguments extends BasicArguments implements Serializable {
    private String consumerTag;
    private String queueName;
    private boolean autoAck;
    // 这个类是调用 basicConsume 方法所需要的参数
    // 还有一个参数，Consumer，是一个回调函数（如何处理消息）
    // 这个回调函数，不能通过网络传输
    // 但是站在 Broker Server 的角度，回调函数是统一的：将收到的消息返回给消费者。
    // 消费者收到消息后，自己去执行自定义的回调函数。
    // 所以消费者就不需要将自己定义的回调函数，告诉服务器了
    // 这个参数也不需要传递了
}
